\begin{abstract}
Streaming join plays a key role in the processing most of streaming queries. General streaming join operator should be able to support multi-attribute joins, provide timeliness guarantee and handle big streaming input. In this paper, we address the design issue of distributed real-time streaming theta-join operator. Our solution adopts handshake join as the base model of streaming processing and extends it to support source-sharing multi-attribute theta-join in the cluster-based topology. Experiments show that our solution has competitive throughput with the primitive handshake join on single machine and high scalability in large-scale distributed cluster.
\end{abstract}
